package com.pk.flink.functions.source;

import org.apache.flink.streaming.api.functions.co.CoMapFunction;

public class MyCoMapFunction implements CoMapFunction<Integer,String,String> {

    @Override
    public String map1(Integer integer) throws Exception {
        return "PK_" + integer * 10;
    }

    @Override
    public String map2(String s) throws Exception {
        return "PK_" + s;
    }
}
